package com.cn.broker;

import com.cn.msg.Message;
import io.netty.channel.Channel;

public class PullRequest {

    private String topic;
    private int queueId;
    private long offset;
    private long suspendTimeStamp;
    private Channel channel;
    private Message message;

    public PullRequest() {
    }

    public PullRequest(String topic, int queueId, long offset, long suspendTimeStamp, Channel channel, Message message) {
        this.topic = topic;
        this.queueId = queueId;
        this.offset = offset;
        this.suspendTimeStamp = suspendTimeStamp;
        this.channel = channel;
        this.message = message;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public int getQueueId() {
        return queueId;
    }

    public void setQueueId(int queueId) {
        this.queueId = queueId;
    }

    public long getOffset() {
        return offset;
    }

    public void setOffset(long offset) {
        this.offset = offset;
    }

    public long getSuspendTimeStamp() {
        return suspendTimeStamp;
    }

    public void setSuspendTimeStamp(long suspendTimeStamp) {
        this.suspendTimeStamp = suspendTimeStamp;
    }

    public Channel getChannel() {
        return channel;
    }

    public void setChannel(Channel channel) {
        this.channel = channel;
    }

    public Message getMessage() {
        return message;
    }

    public void setMessage(Message message) {
        this.message = message;
    }
}
